<?php 
namespace app\http;

use think\queue\Job;
use think\facade\Db;
class Jobs {
	
	public function fire(Job $job,$data){
	
						
	       	$flge=$this->insertOrder($data);
		        if($flge){
	            echo('正在执行'.$data['uid']);
							//$job->delete();
							return true;
						}elseif($job->attempts()>3){
								echo "超过60次";
							$job->delete();
							return false;
							
						}else{
								echo "2秒后重新加入队列";
							//$job->release(2);
							return true;
						}
						
						
						
	}
	public function insertOrder($data){
		    
				 // $data=[
				 // 	'uid'=>$data['uid'],
				 // 	'gid'=>$data['gid'],
				 // 	'num'=>$data['num'],
				 // 	'orderid'=>$data['orderid']
				 // ];
				$res=Db::name('order')->insert($data);
				if($res){
						return true;
					
				}else{
					return false;
				}
				// file_put_contents($data['uid'].".txt",$data);
			
			 
		
	}
	public function queryOrder($id){
	        
 
					
	        return true;
	    }
	    public function failed($data){
	 
	     	echo "失败";
	    }
	
}




